19c9d91aa66d3b3d102dbf44437958f5b7957098,src/org/apache/pig/tools/pigstats/tez/TezVertexStats.java,TezVertexStats,addOutputStatistics,#,271

Before Change


        Map<String, POStore> uniqueOutputs = new HashMap<String, POStore>();
        for (POStore sto : stores) {
            POStoreTez store = (POStoreTez) sto;
            uniqueOutputs.put(store.getOutputKey(), store);
        }

        for (POStore sto : uniqueOutputs.values()) {

After Change


        Map<String, List<POStore>> uniqueOutputs = new HashMap<String, List<POStore>>();
        for (POStore sto : stores) {
            POStoreTez store = (POStoreTez) sto;
            List<POStore> stores = uniqueOutputs.get(store.getOutputKey());
            if (stores == null) {
                stores = new ArrayList<POStore>();
            }
            stores.add(store);
            uniqueOutputs.put(store.getOutputKey(), stores);
        }